package pipeline

type Pipeline struct {
	Id      string      // id 每个数据的id
	PayLoad interface{} //
}

type PipeContext struct {
	Pipelines []Pipeline
	out       <-chan Pipeline
}

type PipeFunc func(pipeline Pipeline) Pipeline

func NewPipeline(id string, payload interface{}) Pipeline {
	return Pipeline{
		Id:      id,
		PayLoad: payload,
	}
}

func (p *Pipeline) start() {

}
